<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %>
<%@page import="dyyx.dto.*"%>
<%@page import="dyyx.util.*"%>
<%@page import="java.util.*"%>
<%@page import="org.apache.kafka.clients.admin.*"%>
<%@page import="org.apache.kafka.common.*"%>


<%

WebResult webResult = new WebResult();
KafkaViewWebUtil.getOffsetInfos(request, webResult);
List<KafkaOffsetInfo> list = webResult.kafkaOffsetInfoList;


if(list==null){
	list = new ArrayList<KafkaOffsetInfo>();
}

%>
<%@include file="/comm.jsp"%>



<hr>
<%=new Date() %> <br>
<%=webResult.msg %>

<hr>
groupId: <%=webResult.groupId %> 
&nbsp; &nbsp; &nbsp; 

<a href="consumer_group_desc.jsp?groupId=<%=webResult.groupId%>">viewConsumerGroupDesc</a>

&nbsp; &nbsp; &nbsp; 

<a href="info.jsp">clusterSummaryInfo</a>


<br>


<hr>

<table>

<tr class='title'>
<td>topic</td>
<td>partition</td>
<td>begin</td>
<td>end</td>
<td>consumer commit</td>
<td>Lag</td>

<td>metadata</td>


</tr>

<%for(KafkaOffsetInfo item:list){ %>


<tr>
<td><a target='_blank' href="topic_desc.jsp?topic=<%=item.topic %>"><%=item.topic %></a></td>
<td><%=item.partition%></td>
<td><%=item.beginning %></td>
<td><%=item.end %></td>
<td><%=item.offset %></td>
<td><%=item.lag() %></td>
<td><%=item.metadata %></td>
</tr>

<%} %>


</table>



